Node / public / rns-proxy / commits / 5fdea09

Parents : 80ef6c0

Author : welo | main nixos computer <empty@empty.com>

Date : 2026-07-08T18:26:49+01:00

removed most print statements

2 files changed, 5 insertions(+), 5 deletions(-)

M src/frame.rs +2 -2

M src/mux.rs +3 -3

--- a/src/frame.rs

+++ b/src/frame.rs

/// Encode a frame into bytes (wire format).

pub fn encode(&self) -> Vec<u8> {

let len = self.payload.len() as u16;

let mut buf = Vec::with_capacity(HDR_SIZE + self.payload.len());

buf.push(self.frame_type as u8);

buf.extend_from_slice(&self.session_id.to_be_bytes());

/// Build a CONNECT frame payload: `[1 byte host_len][host bytes][2 bytes port BE][1 bytes settings]`

/// currently the byte setting only denotes udp but could be used for more in the future

pub fn encode_connect_payload(host: &str, port: u16, udp: bool) -> Vec<u8> {

let h = host.as_bytes();

let mut buf = Vec::with_capacity(1 + h.len() + 2);

--- a/src/mux.rs

+++ b/src/mux.rs

// Send in LINK_MDU-sized chunks

for chunk in encoded.chunks(LINK_MDU) {

if let Err(e) = node.send_on_link(link_id.0, chunk.to_vec(), DATA_CONTEXT) {

warn!("Failed to send link data: {:?}", e);

return;

/// Convenience: send a typed frame.

pub fn send(&self, frame_type: FrameType, session_id: u32, payload: Vec<u8>) {

self.send_frame(&Frame::new(frame_type, session_id, payload));

}

pub fn receive_data(&self, data: &[u8]) -> Vec<Frame> {

let mut buf = self.inner.recv_buf.lock().unwrap();

buf.extend_from_slice(data);

let mut frames = Vec::new();

loop {